草庐IT

Spring boot 整合websocket 客户端

全部标签

go - 使用 Kubernetes 的 Go 客户端列出 Traefik 入口 Controller

我们有一个小的内部工具使用GoclientforKubernetes列出我们的Kubernetes服务.现在我们已经添加了Traefik以使用入口Controller将我们的服务映射到有意义的dns名称。我们看到有一个ingresslisterextension在Kubernetes的Go客户端中,可用于列出入口Controller。但是,我们无法让它发挥作用。是否有列出入口Controller的任何Go客户端代码片段? 最佳答案 到目前为止你尝试了什么?发布示例有帮助。尝试以下任意示例以帮助您入门://imports//metav

go - 如何构建一个可以使用 Go 向多个客户端接收和发送消息的服务器?

我是Go的新手,我正在尝试创建一个服务器,它可以从客户端接收消息并将其发送到其他客户端或任何其他特定客户端。我尝试了很多聊天示例,但我想做的是创建两个文件,一个用于服务器,另一个用于客户端。这是我到目前为止尝试过的代码。server.gopackagemainimport"net"import"fmt"import"bufio"import"strings"funcsend(cnet.Conn){netData,err:=bufio.NewReader(c).ReadString('\n')iferr!=nil{fmt.Println(err)return}temp:=strings.

go - 当其中一个关闭时交换 websocket 连接

使用gorilla/websocket我正在连接到一些websocket(wss)端点并监听消息(只读,不写-这很重要)。此端点始终在10分钟后强制关闭连接。处理连接关闭和重新连接可能会导致一些传入消息丢失。在这种情况下如何处理连接?我的建议是保留连接池(2个或更多连接)。当第一个连接关闭时,我们可以开始使用另一个(已经连接的)连接并开始准备新连接(或只是重新连接)。你怎么看?有什么缺点吗?“交换”连接意味着停止使用一个gorouting并切换到另一个?有什么想法吗?重要提示:端点只是向所有连接广播消息。没有个性化消息、没有身份验证、没有特定于session的状态等。只看书,不写。

gorilla /websocket 设置读取限制?

//SetReadLimitsetsthemaximumsizeforamessagereadfromthepeer.Ifa//messageexceedsthelimit,theconnectionsendsaclosemessagetothepeer//andreturnsErrReadLimittotheapplication.func(c*Conn)SetReadLimit(limitint64){c.readLimit=limit}极限的单位是什么?知识库?MB? 最佳答案 基于gorilla/websocket的来源,以

ssl - 了解 Mutual TLS,使用服务器名的客户端配置

我想了解双向TLS的工作原理,我有以下示例:Ihaveaclientwhowantstoconnecttoserver"svc1.example.com"但是服务器有一个servercertificatewithacommonNameas"svc1.example.cloud"andaSANas"svc.example.test.cloud".现在当我发出GET请求时,我得到以下信息:x509:证书对svc.example.test.cloud有效,对svc1.example.com无效。所以,我的问题是我是否应该对TLSclientConfig进行更改以包含服务器名?或者我应该在TL

go - 如何强制客户端使用 http/2? (而不是退回到 http 1.1)

我如何强制一个简单的Go客户端使用HTTP/2并防止它退回到HTTP1.1?我有一个简单的HTTP/2服务器在“本地主机”上运行,它在回复中返回请求的详细信息。以下是使用GoogleChrome浏览器对此URL的输出:https://localhost:40443/bananasIlikebananas!Method=GETURL=/bananasProto=HTTP/2.0Host=localhost:40443RequestURI=/bananas但这是我为我的Go客户端代码得到的。你可以看到它回落到HTTP1.1Ilikemonkeys!Method=GETURL=/monkey

http - 如何通过代理服务器客户端使用自签名证书

我正在尝试创建一个可以通过代理服务器发送自签名HTTP请求的HTTP客户端。我试过这段代码,但我不确定这里是否有问题,下面的代码会起作用吗?funcCreateProxyClient(serverProxystring,sidstring,portProxyint)(*Client,error){http.DefaultTransport.(*http.Transport).TLSClientConfig=&tls.Config{InsecureSkipVerify:true}proxyUrl,_:=url.Parse(serverProxy+":"+strconv.Itoa(port

web - 通过 websocket 将 kubernetes 日志暴露给浏览器

我正在尝试在kubernetes中使用sidecar模式来创建日志sidecar以公开特定的容器日志。我正在使用kubernetes客户端从kubernetesapi获取日志并通过websocket发送出去。代码如下:funcserveWs(whttp.ResponseWriter,r*http.Request){w.Header().Set("Access-Control-Allow-Origin","*")conn,err:=upgrader.Upgrade(w,r,nil)iferr!=nil{if_,ok:=err.(websocket.HandshakeError);!ok{

google-app-engine - Cloud Datastore 客户端库与 App Engine Go Standard 上的 App Engine SDK

在编写GoAppEngine标准应用程序时,过去的情况是您必须使用AppEngineSDK访问数据存储。然而,最近(从Go1.11开始?),如果你只使用CloudDatastoreClientLibrary似乎就可以了。.在AppEngineStandard上使用CloudDatastore客户端库访问数据存储区是否有缺点?(除了一些额外的配置以使开发应用程序服务器使用模拟器)。优点是它可以为其他环境实现代码重用。 最佳答案 AppEngineStandardforGo1.11在新的第二代(测试版)运行时上运行,它没有第一代的限制,

go - 使用 autocert 保护 websocket 服务器

我正在尝试使用acme/autocert在go中设置一个安全的websocket服务器(wss://)。程序启动,但当我尝试连接到它时出现以下错误:http:TLShandshakeerrorfrom:acme/autocert:unabletoauthorize"";challenge"tls-alpn-01"failedwitherror:acme:authorizationerrorfor:403urn:acme:error:unauthorized:CannotnegotiateALPNprotocol"acme-tls/1"fortls-alpn-01challenge这是我